package cn.xiaobai.contorller;

import cn.xiaobai.spring.boot.annotaion.KafkaTopicsSubscriber;
import cn.xiaobai.spring.boot.annotaion.OnMessage;

/**
 * @Author yangdaji
 * @Date 2023/11/6
 * @PackageName cn.xiaobai.contorller
 * @ClassName Messages
 */
@KafkaTopicsSubscriber(topics = {"flow"}, partition = 0)
public class Messages {

    @OnMessage
    public void onMessage(Object message){
        System.out.println(message);
    }

}
